package com.distributer.delayqueue.delayqueue;

import com.distributer.delayqueue.job.Job;

/**
 * 延迟队列任务处理
 * @author Administrator
 *
 */
public interface ConsumeQueueProvider {

	public void init();
	
	public void comsumer(Job job);
	
	public void destory();
	
}
